package com.test.myrxjava.core;



public interface ObservableSource<T> {//被观察者接口

    /***
     * addObserver
     * @param observer
     */
    void subscribe(Observer observer);//接收观察者

}
